package com.common.thread;

import com.modules.entity.project.ConfigEntity;
import org.json.JSONObject;

/**
 * 接收mqtt消息
 * 
 * @author 57300
 *
 */
public class MqttMsgThread implements Runnable {

	private JSONObject content;

	public MqttMsgThread(JSONObject content) {
		this.content = content;
	}

	@Override
	public void run(){
		try {
			ConfigEntity configEntity = new ConfigEntity();
			// 心跳路径
			if (!content.isNull("cloud_deviceHeartBeat")) {
				String cloud_deviceHeartBeat = (String) content.get("cloud_deviceHeartBeat");
				configEntity.setUrlHeartbeat(cloud_deviceHeartBeat);
			}
			// 拉取路径
			if (!content.isNull("cloud_getdata")) {
				String cloud_getdata = (String) content.get("cloud_getdata");
				configEntity.setUrlPersonal(cloud_getdata);
			}
			// 拉取回调路径
			if (!content.isNull("cloud_back")) {
				String cloud_back = (String) content.get("cloud_back");
				configEntity.setUrlPersonalCallback(cloud_back);
			}
			// 考勤上传
			if (!content.isNull("cloud_callbackurl")) {
				String cloud_callbackurl = (String) content.get("cloud_callbackurl");
				configEntity.setUrlUploadRecord(cloud_callbackurl);
			}
			// 账号
			if (!content.isNull("api_key")) {
				String api_key = (String) content.get("api_key");
				configEntity.setCode(api_key);
			}
			// 密钥
			if (!content.isNull("api_secret")) {
				String api_secret = (String) content.get("api_secret");
				configEntity.setPass(api_secret);
			}
		}catch (Exception e){
			e.printStackTrace();
		}
	}




}
